package ia.programas.server.modelo;

import ia.programas.server.InstanciaCliente;
import ia.programas.server.modelo.aplicaciones.AplicacionAbstracta;
import ia.programas.server.modelo.aplicaciones.AplicacionTest;
import lejos.nxt.remote.NXTCommand;

/**
 * Clase principal en la ejecucion de los programas remotamente.
 * Se asocia 1 instancia a cada cliente, y corre en un hilo aparte de
 * la administracion de la conexion
 * 
 * @author Armando Andini
 *
 */
public class EjecutorAplicaciones extends Thread {

	public InstanciaCliente getCliente() {
		return cliente;
	}

	public void setCliente(InstanciaCliente cliente) {
		this.cliente = cliente;
	}

	public NXTCommInternet getComm() {
		return comm;
	}

	public void setComm(NXTCommInternet comm) {
		this.comm = comm;
	}

	public AplicacionAbstracta getAplicacion() {
		return aplicacion;
	}

	public void setAplicacion(AplicacionAbstracta aplicacion) {
		this.aplicacion = aplicacion;
	}

	public byte[] getBufferRespuesta() {
		return bufferRespuesta;
	}

	public void setBufferRespuesta(byte[] bufferRespuesta) {
		this.bufferRespuesta = bufferRespuesta;
	}

	private InstanciaCliente cliente;
	private NXTCommInternet comm;
	private AplicacionAbstracta aplicacion; // la aplicacion que va a ejecutar el usuario
	private byte[] bufferRespuesta; // aca se va a poner la informacion de respuesta enviada por el robot al server (lecturas,sensado)
	
	
	public EjecutorAplicaciones(InstanciaCliente instanciaCliente) {
		this.cliente = instanciaCliente;
		comm = new NXTCommInternet(cliente);
		aplicacion = new AplicacionTest();
	}
	
	public void iniciarEjecucion(){
		this.start();
	}
	
	@Override
	public void run(){
		//comenzar la ejecucion de un programa
		
		//se setea el singleton de comunicacion con el de este cliente
		//TODO: modificar Lejos, con esto solo puede haber 1 cliente corriendo programas
		NXTCommand.getSingleton().setNXTComm(comm);
		try {
			aplicacion.run();
		} catch (Throwable e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * dormir el thread
	 * se usa para esperar respuesta del robot
	 */
	synchronized public void dormir(){
		try {
			wait();
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/**
	 * despertar el thread dormido previamente
	 */
	synchronized public void despertar(){
		notify();
	}

}
